#include "threadPool.h"

bool isQueryResultExist(MYSQL *conn, const char *sql_query) {
  bool exist = true;
  if (0 != mysql_query(conn, sql_query)) {  // 查询错误
    fprintf(stderr, "isQueryResultExist() query failed: %s\n",
            mysql_error(conn));
  } else {
    MYSQL_RES *result = mysql_store_result(conn);
    if (NULL != result) {  // 返回了结果集
      if (0 != mysql_num_rows(result)) {  // 结果集不为空 查询有结果
        printf("isQueryResultExist() dir existed\n");
        mysql_free_result(result);
      } else {  // 结果集为空 查询无结果
        exist = false;
      }
    } else {  // 未返回结果集 内存分配失败 连接中断
      fprintf(stderr, "isQueryResultExist() store result failed: %s\n",
              mysql_error(conn));
    }
  }
  return exist;
}
